package cn.yuysaln.domain.task.service;

import cn.yuysaln.domain.task.model.entity.TaskEntity;

import java.util.List;

/**
 * 对发送失败的MQ消息进行处理
 */
public interface ITaskService {
    List<TaskEntity> queryNoSendMessageTaskList();

    /**
     * 消息重发
     * @param taskEntity
     */
    void sendMessage(TaskEntity taskEntity);

    //以下为发送消息过后的状态修改方法
    void updateTaskSendMessageCompleted(String userId, String messageId);

    void updateTaskSendMessageFail(String userId, String messageId);
}
